<?php
ini_set('display_errors', 1);
$dir = dirname(dirname(__FILE__));
include($dir.'/__queue_global.php');

class ml_mq_atNick_latestAt extends MqClass{
    const QUEUE_NAME = ML_QUEUENAME_ATNICK_LATESTAT;
    private $oRdsAt;
    private $oBizAt;
    
    public function __construct($queue)
    {
        $this->oBizAt = new ml_biz_atNick_followList();
        
        parent::__construct($queue);
    }    
    
    public function run_job(){
        //接收的数据
        $arr = $this->src_data;
        
        $uid = trim($arr['uid']); 
        $atUid = $arr['atUid'];
        
        if (empty($uid) || empty($atUid)) {
            return ;
        }
        
        $re = $this->oBizAt->update_latestAt_redis($uid, $atUid);
        
    }
    
    
}

$xblog_obj = new ml_mq_atNick_latestAt(new McQueue(ml_mq_atNick_latestAt::QUEUE_NAME));
$argv[1]   = __FILE__;
$xblog_obj->setArgv($argv[1]);
$xblog_obj->execute();